//package com.wondertek.poms.pre.config;
//
//import com.wondertek.poms.common.constant.Constants;
//import org.apache.activemq.ActiveMQConnectionFactory;
//import org.apache.activemq.command.ActiveMQQueue;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.jms.annotation.EnableJms;
//import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
//import org.springframework.jms.config.JmsListenerContainerFactory;
//
//import javax.jms.Queue;
//
///**
// * <p><b>ActiveMQConfig Description:</b> activemq配置</p>
// * @author douzi
// * <b>DATE</b> 2020年3月10日 上午10:27:22
// */
//@Configuration
//@EnableJms
//public class ActiveMQConfig {
//    @Value("${spring.activemq.user}")
//    private String usrName;
//
//    @Value("${spring.activemq.password}")
//    private  String password;
//
//    @Value("${spring.activemq.broker-url}")
//    private  String brokerUrl;
//
//    @Bean
//    public Queue contentQueue() {
//        return new ActiveMQQueue(Constants.QUEUE_SYNC_CONTENT);
//    }
//
//    @Bean
//    public Queue pomsNewQueue() {
//        return new ActiveMQQueue(Constants.QUEUE_NEW_POMS_SYNC);
//    }
//
//    @Bean
//    public Queue transImgQueue() {
//        return new ActiveMQQueue(Constants.QUEUE_TRANS_IMG);
//    }
//
//
//    @Bean
//    public Queue publishQueue() {
//        return new ActiveMQQueue(Constants.QUEUE_SYNC_PUBLISH);
//    }
//
//    @Bean
//    Queue delayQueue() {
//        return new ActiveMQQueue(Constants.QUEUE_SLOW_SYNC_CONTENT);
//    }
//
//    @Bean
//    public ActiveMQConnectionFactory connectionFactory() {
//        return new ActiveMQConnectionFactory(usrName, password, brokerUrl);
//    }
//
//    @Bean
//    public JmsListenerContainerFactory<?> jmsListenerContainerQueue(ActiveMQConnectionFactory connectionFactory){
//        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
//        factory.setPubSubDomain(false);
//        factory.setConnectionFactory(connectionFactory);
//        // 开启持久化
////        factory.setSubscriptionDurable(true);
//        return factory;
//    }
//
//    @Bean
//    public JmsListenerContainerFactory<?> jmsListenerContainerTopic(ActiveMQConnectionFactory connectionFactory){
//        DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();
//        //设置为发布订阅方式, 默认情况下使用的生产消费者方式
//        bean.setPubSubDomain(true);
//        bean.setConnectionFactory(connectionFactory);
//        // 开启持久化
////        bean.setSubscriptionDurable(true);
//        return bean;
//    }
//}
